package space.xxhui.config

/**
 * @author HitvzByHui
 *         date 2021-09-12
 */
object StreamingConf {

  // parameters configuration
  val nGram = 3
  val updateFreq = 300000 //5min


  // spark configuration
  val master = "spark://127.0.0.1:7077"
  val localDir = "/Users/hui/code/data/wordFreqLogDir"
  val perMaxRate = "5"
  val interval = 3 // seconds
  val parallelNum = "15"
  val executorMem = "1G"
  val concurrentJobs = "5"
  val coresMax = "3"

  // kafka configuration
  val brokers = "175.27.191.203:9092,175.27.191.203:9093"
  val zk = "175.27.191.203:2181"
  val group = "wordFreqGroup"
  val topics = "wordFreq"

}
